package com.raven.play.stream.test;

import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.stream.javadsl.Source;
import org.junit.jupiter.api.Test;

public class StreamTest2 {

    private final ActorSystem system = ActorSystem.create("QuickStart");
    private final LoggingAdapter log = Logging.getLogger(system, this);

    @Test
    public void test001() {
        final Source<Integer, NotUsed> source = Source.range(1, 10);
        source.runForeach(System.out::println, system);
        log.info("Done");
    }

}
